package com.sjz.test2;

import java.util.Arrays;
import java.util.List;
import java.util.Optional;
import java.util.stream.Stream;

import org.junit.Test;

import com.sjz.test2.Employee.Status;
import com.sun.xml.internal.ws.api.addressing.AddressingVersion.EPR;

/*
 * 一、 Stream 的操作步骤
 * 
 * 1. 创建 Stream
 * 
 * 2. 中间操作
 * 
 * 3. 终止操作
 */
public class TestStreamAPI2 {
	
	
	       List<Employee> emps = Arrays.asList(
			new Employee(102, "李四", 59, 6666.66, Status.BUSY),
			new Employee(103, "王五", 28, 3333.33, Status.VOCATION),
			new Employee(104, "赵六", 8, 7777.77, Status.BUSY),
			new Employee(104, "赵六", 8, 7777.77, Status.FREE),
			new Employee(104, "赵六", 8, 7777.77, Status.FREE),
			new Employee(101, "张三", 18, 9999.99, Status.FREE),
			new Employee(105, "田七", 38, 5555.55, Status.BUSY)
	);
	
	       
	     //3. 终止操作
	   	/*
	   		allMatch——检查是否匹配所有元素
	   		anyMatch——检查是否至少匹配一个元素
	   		noneMatch——检查是否没有匹配的元素
	   		findFirst——返回第一个元素
	   		findAny——返回当前流中的任意元素
	   		count——返回流中元素的总个数
	   		max——返回流中最大值
	   		min——返回流中最小值
	   	 */
	@Test
	public void test1() {
		//  boolean test(T t);
		boolean allMatch = emps.stream().allMatch((e)->e.getStatus().equals(Status.BUSY)); 
	    System.out.println("检查是否匹配所有元素："+allMatch); //false
	    System.out.println("**********************************************************");
	    boolean anyMatch = emps.stream().anyMatch((e)->e.getStatus().equals(Status.BUSY));
	    System.out.println("检查是否至少匹配一个元素:"+anyMatch);//true
	    System.out.println("**********************************************************");
	    boolean noneMatch = emps.stream().noneMatch((e)->e.getStatus().equals(Status.BUSY));
	    System.out.println("检查是否没有匹配的元素："+anyMatch);//true
	    System.out.println("**********************************************************");
	     Optional<Employee> findFirst = emps.stream().findFirst();
	     Employee employee = findFirst.get();
	     System.out.println(employee);//得到第一个元素
	     System.out.println("**********************************************************");
	     Optional<Employee> findFirst2 = emps.stream().sorted((x,y)->Double.compare(x.getSalary(), y.getSalary()))
	     .findFirst();
	     System.out.println(findFirst2.get());   //得到最低的一条数据
	     System.out.println("**********************************************************");
	     Optional<Employee> findFirst3= emps.stream().sorted((x,y)->Double.compare(y.getSalary(),x.getSalary()))
	     .findFirst();
	     System.out.println(findFirst3.get()); //得到最高的一条数据
	     System.out.println("**********************************************************");
	     Optional<Employee> findAny = emps.stream().filter((e)->e.getStatus().equals(Status.FREE))
	     .findAny();
	     System.out.println("返回当前流中的任意元素:"+findAny.get());   //得到状态是FREE的任意一条数据
	     System.out.println("**********************************************************");
	     System.out.println("集合的长度是："+emps.stream().count());
	     System.out.println("**********************************************************");
	     //int compare(T o1, T o2);
	     Optional<Employee> max = emps.stream().max((x,y)->Integer.compare(x.getAge(), y.getAge()));
	     System.out.println("年级最大的："+max.get());
	     //  R apply(T t);
	     Optional<Double> max2 = emps.stream().map(Employee::getSalary).max(Double::compare);
	     System.out.println("薪水最多的是："+max2.get());
	     System.out.println("**********************************************************");
	     //int compare(T o1, T o2);
	     Optional<Employee> min = emps.stream().min((x,y)->Integer.compare(x.getAge(), y.getAge()));
	     System.out.println("年级最小的是："+min.get());
	     Optional<Double> min2 = emps.stream().map((x)->x.getSalary()).min((x,y)->Double.compare(x, y));
	     System.out.println("薪水最少的是："+min2.get());
	}
	
	//注意：流进行了终止操作后，不能再次使用   执行会报错
	@Test
	public void  test2() {
		
		Stream<Employee> stream = emps.stream()
				 .filter((e) -> e.getStatus().equals(Status.FREE));
				
				long count = stream.count();
				
				stream.map(Employee::getSalary)
					.max(Double::compare);
	}
}
